package o;

import com.huawei.hmf.orb.exception.ConnectRemoteException;
import java.util.Map.Entry;
import java.util.concurrent.atomic.AtomicBoolean;

public class ffd extends fhs implements fex {
    public static final ffj ˋ = new ffj() {
        public ffd ˎ(ffa o_ffa) throws ConnectRemoteException {
            ffd ˊ = ffi.ˊ(o_ffa.ˎ());
            return ˊ != null ? ˊ : new ffd(o_ffa);
        }
    };
    private AtomicBoolean ˎ = new AtomicBoolean(false);
    private final ffa ॱ;

    protected ffd(ffa o_ffa) throws ConnectRemoteException {
        super(false);
        this.ॱ = o_ffa;
        ffi.ˎ(this.ॱ.ˎ(), this);
        if (o_ffa.ˏ()) {
            ॱ();
        } else {
            o_ffa.ˏ(this);
        }
    }

    public void ˋ() {
        ffi.ˎ(this.ॱ.ˎ(), this);
        ॱ();
        this.ˎ.set(true);
    }

    public void ˊ() {
        ffi.ˋ(this.ॱ.ˎ());
        ˏ();
        this.ˎ.set(false);
    }

    public void ˊ(ConnectRemoteException connectRemoteException) {
        ˊ();
    }

    public boolean ˎ() {
        return this.ˎ.get();
    }

    protected void ॱ() {
        for (Entry entry : this.ॱ.ˋ().entrySet()) {
            String str = (String) entry.getKey();
            new ffg(new ffn(str, this.ॱ)).ˏ(this, str, (fhu) entry.getValue());
        }
    }

    protected void ˏ() {
        ᐝ();
    }
}
